package com.gitee.xhs.customFunction;

import com.gitee.xhs.sampleRecod.transactionRecord.Transaction;
import org.apache.flink.api.java.functions.KeySelector;

/**
 * @author BigHead
 * @date 2022/7/19 11:20
 * @description OperatorKeyBy
 */
public class OperatorKeyBy implements KeySelector<Transaction, Long> {

    @Override
    public Long getKey(Transaction value) throws Exception {
        return value.getAccountId();
    }

}
